#include "head.h"


// 初始化mysql，并建立连接
int MysqlInit(MYSQL* mysql)
{
    char user[10] = {0};
    char passwd[10] = {0};
    char db[20] = {0};
    getparameter("user", user);
    getparameter("passwd", passwd);
    getparameter("db", db);


    mysql_init(mysql);
    ERROR_CHECK(mysql, NULL, "mysql_init");

    // TODO 加锁
    if(mysql_real_connect(mysql, "localhost", user, passwd, db, 0, NULL, 0) == NULL)
        LOG_MSG("mysql连接失败");
    LOG_MSG("mysql连接成功");
  
    // TODO 解锁
    return 0;
}

// 得到用户的 id
int usr_id(MYSQL* mysql, const char* usr)
{
    char sql[200] = {0};
    sprintf(sql, "select * from usr where usr_name = '%s'", usr);
    LOG_MSG(sql);
    if(mysql_query(mysql, sql) != 0)
        LOG_MSG("mysql_query");

    MYSQL_RES* res = mysql_store_result(mysql);
    ERROR_CHECK(res, NULL, "mysql_store_result");
    if(mysql_num_rows(res) == 0)
    {
        LOG_MSG("mysql_store_result");
        mysql_free_result(res);
        return -1;
    }
    MYSQL_ROW line = mysql_fetch_row(res);
    // 得到用户id    
    int uid = atoi(line[0]);
    mysql_free_result(res);
    
    return uid;
}